package ebj.common.httpclient;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

//import net.sf.json.JSONArray;

import org.apache.commons.lang.exception.ExceptionUtils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.NameValuePair;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.protocol.HTTP;
import org.apache.http.util.EntityUtils;


public class APIHttpClient {

    //接口地址
    private String apiURL = "";
    private Log logger = LogFactory.getLog(this.getClass());
    private static final String pattern = "yyyy-MM-dd HH:mm:ss:SSS";
        private HttpClient httpClient = null;
    private HttpPost method = null;
    private long startTime = 0L;
    private long endTime = 0L;
    private int status = 0;
    /**
     * 接口地址
     * @param url
     */
    public APIHttpClient(String url){

        if(url != null)
        {
            this.apiURL = url;
        }
        if(apiURL != null)
        {
                    httpClient = new DefaultHttpClient();
                    method = new HttpPost(apiURL);
            
        }
    }
    
    /**
     * 调用 API
     * @param parameters
     * @return
     */
    public String post(String parameters)
    {
        String body = null;
                logger.info("parameters:" + parameters);
                
                
        if(method != null & parameters != null  && !"".equals(parameters.trim()))
        {
//                    JSONArray jsonObject = JSONArray.fromObject(parameters);
//                    logger.info("json:" + jsonObject.toString());
                    try{

                        List<NameValuePair> params=new ArrayList<NameValuePair>();  
                        //建立一个NameValuePair数组，用于存储欲传送的参数  
                        params.add(new BasicNameValuePair("data",parameters));  
                        //添加参数  
                        method.setEntity(new UrlEncodedFormEntity(params,HTTP.UTF_8));  
                        
                        startTime = System.currentTimeMillis();
                                
                        //设置编码  
                        HttpResponse response=httpClient.execute(method);  
                        endTime = System.currentTimeMillis();
                        int statusCode = response.getStatusLine().getStatusCode();
                        logger.info("statusCode:" + statusCode);
                         logger.info("调用API 花费时间(单位：毫秒)：" + (endTime - startTime));
                        if(statusCode != HttpStatus.SC_OK){
                            logger.error("Method failed:"+response.getStatusLine());
                            status = 1;
                        }
                        
                            //Read the response body
                             body=EntityUtils.toString(response.getEntity()); 
                        
            }catch(IOException e){
                //发生网络异常
                logger.error("exception occurred!\n"+ExceptionUtils.getFullStackTrace(e));
                //网络错误
                status = 3;
            }
                    finally{
                        logger.info("调用接口状态：" + status);
                    }
                    
            
        }
        return body;
    }

    /**
     * 0.成功 1.执行方法失败 2.协议错误 3.网络错误
     * @return the status
     */
    public int getStatus() {
        return status;
    }

    /**
     * @param status the status to set
     */
    public void setStatus(int status) {
        this.status = status;
    }
    /**
     * @return the startTime
     */
    public long getStartTime() {
        return startTime;
    }
    /**
     * @return the endTime
     */
    public long getEndTime() {
        return endTime;
    }
}

